package com.shux.kafka.consumer;
/**
 * 描述：
 * 
 * <pre>HISTORY
 * ****************************************************************************
 *  ID   DATE           PERSON          REASON
 *  1    2017年9月18日      Simba.Hua         Create
 * ****************************************************************************
 * </pre>
 * @author Simba.Hua
 */
public class ConsumerConfig {
	private String topic;
	private String kafkaServer;
	private String systemIdToken;
	private Integer consumerThreadCount;
	public ConsumerConfig(String kafkaServer,String topic, String systemIdToken,
			Integer consumerThreadCount) {
		super();
		this.kafkaServer = kafkaServer;
		this.topic = topic;
		this.systemIdToken = systemIdToken;
		this.consumerThreadCount = consumerThreadCount;
	}
	public String getTopic() {
		return topic;
	}
	public void setTopic(String topic) {
		this.topic = topic;
	}
	public String getSystemIdToken() {
		return systemIdToken;
	}
	public void setSystemIdToken(String systemIdToken) {
		this.systemIdToken = systemIdToken;
	}
	public Integer getConsumerThreadCount() {
		return consumerThreadCount;
	}
	public void setConsumerThreadCount(Integer consumerThreadCount) {
		this.consumerThreadCount = consumerThreadCount;
	}
	public String getKafkaServer() {
		return kafkaServer;
	}
	public void setKafkaServer(String kafkaServer) {
		this.kafkaServer = kafkaServer;
	}
	
	
}
